

package com.hazelcast.map.impl.querycache;

import com.hazelcast.cluster.Member;
import com.hazelcast.spi.impl.operationservice.Operation;

import java.util.concurrent.Future;

/**
 * Provides abstraction over client and node side invocations.
 */
public interface InvokerWrapper {

    Future invokeOnPartitionOwner(Object request, int partitionId);

    Object invokeOnAllPartitions(Object request, boolean urgent) throws Exception;

    Future invokeOnTarget(Object operation, Member member);

    Object invoke(Object operation, boolean urgent);

    void executeOperation(Operation op);
}
